package week13.queue.api;

public interface Broker {

    Producer getProducer(String topicName);

    Consumer getConsumer(String topicName,ConsumerGroup consumerGroup);
}
